#coding=utf-8
'''
Created on Apr 22, 2016

@author: root
'''
'''
趙实现
'''
import os,time,xmlrpclib
def vdisk(args={}):
    keyword=args['keyword']
    data=''
    if keyword=='':
        keyword=''
    #keyword=u'经济 15% 南洋科技'
    list=keyword.split(' ')
    #print list
    s=''
    #拼接关键字
    for item in list:
        s+=item+' '
        
    if not os.path.exists("/tmp/virtio_blk/"):
        os.mkdir("/tmp/virtio_blk")
    #print s
    root='blk/virtio_blk'
    if not os.path.exists('/tmp/virtio_write.log'):
        return xmlrpclib.Binary('error')
            
    error=os.system(root+'/run.sh '+'/tmp/virtio_write.log '+s)
    #os.mkdir('/tmp/virtio_blk')
    #print os.path.exists(root)
    num=len(list)#关键字个数    
   
    #error=os.system('/tmp/virtio_blk/TestJAVA.sh '+'/tmp/virtio_write.log '+s)
    #print error
    if not error:
        while num:
            for filename in list:
                filepath='/tmp/virtio_blk/'+filename+'.txt'
                if os.path.exists(filepath):
                    num-=1
                    #说明文件个数不够，继续等待知道文件个数和list长度大小一致
            print num
            if num:
                num=len(list)
                             #睡眠1秒在查找
                time.sleep(1000)
            
                #此时文件必定以及全部存在
        for filename in list:
                filepath='/tmp/virtio_blk/'+filename+'.txt'
                fo=open(filepath)
                try:
                    data+=fo.read()+'\n'
                finally:
                    fo.close()
        return xmlrpclib.Binary(data.replace('[.:,;\\]',''))
    else:
        return xmlrpclib.Binary('error')